45bf1df2b20e0413da4db01ee5a170150922b852,messaging-activemq/src/main/java/org/wildfly/extension/messaging/activemq/DiscoveryGroupAdd.java,DiscoveryGroupAdd,recordCapabilitiesAndRequirements,#OperationContext#ModelNode#Resource#,68
Before Change
@Override
protected void recordCapabilitiesAndRequirements(OperationContext context, ModelNode operation, Resource resource) throws OperationFailedException {
super.recordCapabilitiesAndRequirements(context, operation, resource);
ModelNode model = resource.getModel();
if (CommonAttributes.JGROUPS_CHANNEL.resolveModelAttribute(context, model).isDefined() && !DiscoveryGroupDefinition.JGROUPS_STACK.resolveModelAttribute(context, model).isDefined()) {
context.registerAdditionalCapabilityRequirement(JGroupsDefaultRequirement.CHANNEL_FACTORY.getName(), RuntimeCapability.buildDynamicCapabilityName(DiscoveryGroupDefinition.CHANNEL_FACTORY_CAPABILITY.getName(), context.getCurrentAddressValue()), DiscoveryGroupDefinition.JGROUPS_STACK.getName());
}
}
After Change
@Override
protected void recordCapabilitiesAndRequirements(OperationContext context, ModelNode operation, Resource resource) throws OperationFailedException {
//super.recordCapabilitiesAndRequirements(context, operation, resource);
String discoveryGroupName = context.getCurrentAddressValue();
String serverName = context.getCurrentAddress().getParent().getLastElement().getValue();
String compositeName = serverName + "." + discoveryGroupName;
context.registerCapability(DiscoveryGroupDefinition.CHANNEL_FACTORY_CAPABILITY.fromBaseCapability(compositeName));